package SparkStreaming;

import org.apache.hadoop.conf.Configuration;
import org.apache.spark.api.java.JavaSparkContext;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.util.HashMap;

/**
 * <pre>
 * Created with IntelliJ IDEA.
 * User: zhengzhi
 * Date: 2017/4/12
 * To change this template use File | Settings | File Templates.
 * </pre>
 */
public class Readkafka {

    private static final Logger LOG = LoggerFactory.getLogger(Readkafka.class);

    protected transient Configuration hadoopConf;
    protected transient JavaSparkContext javaSparkContext ;


    public Readkafka(Configuration hadoopConf,JavaSparkContext javaSparkContext){
        this.hadoopConf = hadoopConf;
        this.javaSparkContext = javaSparkContext;
    }


    public  void startSparkJob(){


    }


}
